c0c467e781ced532684d4867fd0585dea97ebab4,TwitterScanner/src/com/continuuity/examples/twitter/TwitterProcessor.java,TwitterProcessor,initialize,#,40

Before Change


    this.wordCounts = (CounterTable)
        getFlowletContext().getDataSetRegistry().registerDataSet(
            new CounterTable("wordCounts"));
    this.topHashTags = (SortedCounterTable)
        getFlowletContext().getDataSetRegistry().registerDataSet(
            new SortedCounterTable("topHashTags",
            new SortedCounterTable.SortedCounterConfig()));
    this.topUsers = (SortedCounterTable)
        getFlowletContext().getDataSetRegistry().registerDataSet(
            new SortedCounterTable("topUsers",

After Change


  @Override
  public void initialize() {
    this.topHashTags = getFlowletContext().getDataSet(TwitterFlow.topHashTags);
    this.topUsers = getFlowletContext().getDataSet(TwitterFlow.topUsers);

    this.wordCounts = getFlowletContext().getDataSet(TwitterFlow.wordCounts);
    this.hashTagWordAssocs = getFlowletContext().getDataSet(TwitterFlow.hashTagWordAssocs);